package com.dsw.rebbit.producers;

import com.dsw.rebbit.utils.ConnectionUtils;
import com.rabbitmq.client.*;
import org.junit.Test;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

/**
 * 生产者 发送消息
 */
public class ProducersMQ {

    private static final String QUEUE_NAME="QUEUE_PRODUCERS"; //队列名称

    /**
     * 发送消息的方法
     */
    @Test
    public void sendMsg() throws IOException, TimeoutException {
        //获取连接
        Connection connection= ConnectionUtils.getConnection();
        //创建连接通道
        Channel channel=connection.createChannel();
        boolean durable=false;
        boolean exclusive=false;
        boolean autoDelete=false;
        channel.queueDeclare(QUEUE_NAME, durable, exclusive, autoDelete, null);//如果这个队列不存在会创建队列,其实 这句话是不需要的
        String msg="Hello World";
        channel.basicPublish("",QUEUE_NAME,null,msg.getBytes());//发送消息
        System.out.printf("------------"+msg);
        channel.close();
        connection.close();
    }
}
